"""
使用Python进行操作MySQL数据库
pymysql       --- pip install pymysql

1、导包
2、创建连接【连接地址、用户名、密码、数据库名、端口：3306、编码集：utf-8】
3、创建游标      使用连接对象进行创建
4、准备要执行的SQL语句
5、执行SQL语句
6、关闭游标
7、关闭连接

异常捕获
try：
    要监控的代码     --- 这里的代码是一定会执行，但是这里的代码不一定会有异常
except 异常的具体类型：
    出现异常时给出的解决方案或提示信息   --- 只有出现异常时才会执行没有异常不会执行
except 异常的具体类型：
    出现异常时给出的解决方案或提示信息
except Exception as e：
    出现异常时给出的解决方案或提示信息
finally：
    不管监控的代码有没有出现异常，这里的代码是都会执行的

with 表达式 as 变量：
    语句执行体



"""
# # 1、导包
# import pymysql
# # 2、创建连接【连接地址、用户名、密码、数据库名、端口：3306、编码集：utf-8】
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# # 3、创建游标      使用连接对象进行创建
# cursor = db.cursor()
# # 4、准备要执行的SQL语句
# sql = "select * from t_dept where deptno=%s"
# pram = (1,)
# # 5、执行SQL语句
# cursor.execute(sql,pram)
# data = cursor.fetchall()
# print(data, type(data))
# for item in data:
#     print(item)
# # 6、关闭游标
# cursor.close()
# # 7、关闭连接
# db.close()

# # 1、导包
# import pymysql
# # 2、创建连接【连接地址、用户名、密码、数据库名、端口：3306、编码集：utf-8】
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# # 3、创建游标      使用连接对象进行创建
# cursor = db.cursor()
# # 4、准备要执行的SQL语句
# # sql = "insert into t_dept values (6,'研发部','郑州')"
# data = ("(7,'研发部','郑州'),"
#         "(8,'研发部','郑州'),"
#         "(9,'研发部','郑州')")
# sql = f"insert into t_dept values {data}"
# # 5、执行SQL语句
# cursor.execute(sql)
# db.commit()
# # 6、关闭游标
# cursor.close()
# # 7、关闭连接
# db.close()

# # 1、导包
# import pymysql
# # 2、创建连接【连接地址、用户名、密码、数据库名、端口：3306、编码集：utf-8】
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# # 3、创建游标      使用连接对象进行创建
# cursor = db.cursor()
# # 4、准备要执行的SQL语句
# sql = "update t_dept set loc='北京' where deptno=9"
# # 5、执行SQL语句
# cursor.execute(sql)
# db.commit()
# # 6、关闭游标
# cursor.close()
# # 7、关闭连接
# db.close()

# # 1、导包
# import pymysql
# # 2、创建连接【连接地址、用户名、密码、数据库名、端口：3306、编码集：utf-8】
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# # 3、创建游标      使用连接对象进行创建
# cursor = db.cursor()
# # 4、准备要执行的SQL语句
# sql = "delete from t_dept where deptno=9"
# # 5、执行SQL语句
# cursor.execute(sql)
# db.commit()
# # 6、关闭游标
# cursor.close()
# # 7、关闭连接
# db.close()

# import pymysql
#
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# try:
#     with db.cursor() as cursor:
#         sql = "select * from t_dept"
#         cursor.execute(sql)
#         data = cursor.fetchall()
#         print(data, type(data))
#         for item in data:
#             print(item)
# except Exception as e:
#     print('数据库操作异常：', e)
# finally:
#     db.close()

# import pymysql
#
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# try:
#     with db.cursor() as cursor:
#         sql = "insert into t_dept values (9,'测试部','上海')"
#         cursor.execute(sql)
#         db.commit()
#         print('数据插入成功！')
# except Exception as e:
#     print('数据库插入失败：', e)
# finally:
#     db.close()

# import pymysql
#
# db = pymysql.connect(
#     host='127.0.0.1',
#     user='root',
#     password='root',
#     database='company',
#     port=3306,
#     charset='utf8'
# )
# try:
#     with db.cursor() as cursor:
#         sql = "update t_dept set loc='深圳' where deptno=9"
#         cursor.execute(sql)
#         db.commit()
#         print('数据更新成功！')
# except Exception as e:
#     print('数据库更新失败：', e)
# finally:
#     db.close()

import pymysql

db = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='root',
    database='company',
    port=3306,
    charset='utf8'
)
try:
    with db.cursor() as cursor:
        sql = "delete from t_dept where deptno=9"
        cursor.execute(sql)
        db.commit()
        print('数据删除成功！')
except Exception as e:
    print('数据库删除失败：', e)
finally:
    db.close()





















